import os


REDIS_SETTING = {
    'host': os.environ.get("hostname", "127.0.0.1"),
    'port': os.environ.get("hostname", 19007),
    'password': os.environ.get("hostname", "123456"),
    'decode_responses': os.environ.get("hostname", True),  # 关键参数
    'charset': os.environ.get("hostname", "utf-8"),  # 默认编码
    'db': os.environ.get("hostname", 1)
}

MQTT_SETTING = {
    "hostname": os.environ.get("hostname", "127.0.0.1"),
    "port": os.environ.get("port", 1883),
    "username": os.environ.get("username", "test001"),
    "password": os.environ.get("password", "test001")
}

KAFKA_ALGO_PUSH_SETTING = {
    "kafka_servers": os.environ.get(
        "KAFKA_ALGO_PUSH_SERVERS",
        "127.0.0.1:9092"
    ),
    "kafka_topic": os.environ.get("KAFKA_ALGO_PUSH_TOPIC", "shaojie_data")
}

MINIO_SETTING = {
    "endpoint": os.environ.get("MINIO_ENDPOINT", "127.0.0.1:9000"),
    "access_key": os.environ.get("MINIO_ACCESS_KEY", "equota"),
    "secret_key": os.environ.get("MINIO_SECRET_KEY", "Equota@123"),
    "secure": bool(int(os.environ.get("MINIO_SECURE", 0))),
}

TDENGINE_SETTINGS = {
    "host": os.environ.get("TDENGINE_HOST", "127.0.0.1"),
    "port": int(os.environ.get("TDENGINE_PORT", "6041")),
    "username": os.environ.get("TDENGINE_USERNAME", "root"),
    "password": os.environ.get("TDENGINE_PASSWORD", "taosdata"),
    "keep": os.environ.get("TDENGINE_KEEP", 365),
    "database": os.environ.get("TDENGINE_DATABASE", "nan_steel_shaojie"),
    "precision": os.environ.get("TDENGINE_PRECISION", "ms"),
    "timezone": os.environ.get("TDENGINE_TIMEZONE", None),
    "returned_timezone": os.environ.get("TDENGINE_RETURNED_TIMEZONE", None)
}

TDENGINE_DATABASE: dict = {
    'url': os.environ.get('TDENGINE_URL', 'http://127.0.0.1:6041/rest/sql/{}?tz=Asia/Shanghai'),
    'auth': (os.environ.get('TDENGINE_USER', 'root'), os.environ.get('TDENGINE_PASSWORD', 'taosdata'))
}